package com.hub.realtime.common.model;

import lombok.Data;

@Data
public class CheckPointConf {
    private String checkPointModel="EXACTLY_ONCE";
    private Long checkPintInterval=1000L;
    private Long checkPointTimeout=60*1000*5L;
    private Long minPauseBetweenCheckpoints=5000L;
    private Integer maxConcurrentCheckpoints=1;
    private String checkpointCleanup="RETAIN_ON_CANCELLATION";
    private Boolean preferCheckpointForRecovery=false;
    private Boolean enableUnalignedCheckpoints=false;
    //ProcessingTime, IngestionTime, EventTime
    private String timeCharacteristic="ProcessingTime";
}
